package com.base.quickstart;

import com.lmax.disruptor.EventHandler;

/**
 * 消费端
 * @author xuyou
 * @date 2022年08月08日 7:46
 */
public class OrderEventHandler implements EventHandler<OrderEvent> {


    /**
     * 当有消息时,这个方法就会被调用
     * @author xuyou
     * 2022/8/8 0008 7:47
     * @param event 订单事件
     * @param sequence
     * @param endOfBatch
    */
    @Override
    public void onEvent(OrderEvent event, long sequence, boolean endOfBatch) throws Exception {
        //Thread.sleep(Integer.MAX_VALUE);
        System.err.println("消费者: " + event.getValue());
    }
}
